﻿using MySqlSync.Core.Models;

namespace MySqlSync.Core.Interfaces
{
    /// <summary>
    /// Kafka生产者服务接口
    /// </summary>
    public interface IKafkaProducerService : IDisposable
    {
        /// <summary>
        /// 发送同步记录到Kafka
        /// </summary>
        Task SendMessageAsync(SyncRecord record);

        /// <summary>
        /// 确保所有消息都已发送
        /// </summary>
        Task FlushAsync();
    }

}
